package com.carrot.mq.common;

import java.io.Serializable;

/**
 * @author 兴趣使然黄小黄
 * @version 1.0
 * @date 2023/8/28 20:02
 */
public class BasicConsumeArguments extends BasicArguments implements Serializable {

    private String consumerTag;

    private String queueName;

    private boolean autoAck;

    // basicConsume 方法中的回调函数不能通过网络传输的 (Consumer consumer 其实没必要传输)
    // 但是, 针对 broker server 对于消息的处理回调就是把消息返回给客户端
    // 客户端在收到消息后, 再在客户端自己执行一个用户自定义的回调

    public String getConsumerTag() {
        return consumerTag;
    }

    public void setConsumerTag(String consumerTag) {
        this.consumerTag = consumerTag;
    }

    public String getQueueName() {
        return queueName;
    }

    public void setQueueName(String queueName) {
        this.queueName = queueName;
    }

    public boolean isAutoAck() {
        return autoAck;
    }

    public void setAutoAck(boolean autoAck) {
        this.autoAck = autoAck;
    }
}
